/*
package cn.itcast.kafka.aitest;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

*/
/**
 * Kafka消息生产者
 *//*

@Component
public class KafkaMessageProducer {

    // 注入Kafka模板
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    // 发送消息的主题
    private static final String TOPIC = "test-topic";

    */
/**
     * 发送消息到Kafka
     * @param message 要发送的消息内容
     *//*

    public void sendMessage(String message) {
        // 发送消息并处理结果
        kafkaTemplate.send(TOPIC, message)
                .addCallback(
                        result -> System.out.println("消息发送成功：" + message),
                        ex -> System.err.println("消息发送失败：" + ex.getMessage())
                );
    }

    */
/**
     * 发送带键的消息到Kafka
     * @param key 消息键
     * @param message 消息内容
     *//*

    public void sendMessageWithKey(String key, String message) {
        kafkaTemplate.send(TOPIC, key, message)
                .addCallback(
                        result -> System.out.println("消息发送成功 [key=" + key + "]: " + message),
                        ex -> System.err.println("消息发送失败 [key=" + key + "]: " + ex.getMessage())
                );
    }
}
*/
